<<<<<<< HEAD
const mysql = require('mysql');
 
// 创建连接池
const pool = mysql.createPool({
  connectionLimit: 10,
  //主机地址
  host: '127.0.0.1',
  //用户名
  user: 'root',
  //密码
  password: 'jiayou7777',
  //数据库名称
  database: 'juzao',
  connectTimeout: 6000,
  multipleStatements: true,
  charset:'utf8mb4',
  supportBigNumbers:true,
  bigNumberStrings:true
})
 
// 当不再需要连接池时，可以关闭连接池
// pool.end();

module.exports = {
  query(sql){
    return new Promise(next =>{
      // 从连接池获取连接
      pool.getConnection((err, connection) => {
        if (err) throw err; // 如果有错误，抛出错误
      
        // 使用连接执行查询
        connection.query(sql, (error, results, fields) => {
          if(error) console.log(error)
          // 处理查询结果
          next(error ? { errorMsg : error.message } : results)
      
          // 释放连接
          connection.release()
      
          // 如果需要关闭连接池，可以调用pool.end()
        })
      })
    })
  }
=======
//node连接MySQL数据库
const mysql = require ('mysql')
//创建连接
let conn = mysql.createConnection({
    //主机地址
    host: 'localhost',
    //用户名
    user: 'root',
    //密码
    password: 'root',
    //数据库名称
    database: 'juzao',
    connectTimeout: 3306,
    multipleStatements: true
})
  
module.exports = {
  query(sql){
    return new Promise(next =>{
      conn.connect()
      conn.query(sql, function (error, results, fields) {
        if (error) throw error;
        next(results)
        // conn.end()
      })
    })
  }
>>>>>>> 44f7ea2 (newbranch)
}